import com.shujia.traffic.common.SparkUtil
import org.apache.spark.sql.DataFrame

object Demo01 extends SparkUtil{

  override def run(): Unit = {

    print(day)
    val df: DataFrame = sparkSession
      .read
      .format("csv")
      .load("traffic/data/wfkj.txt")

    df.show()
  }
}
